<?php
namespace app\utils;

use yii\helpers\Json;

class WebSocketUtil {

    /**
     * @param integer $msg_type 消息类型
     * @param integer $event_type 事件类型
     * @param integer $to 用户ID
     * @param mixed $data 数据包
     * @return false|int
     */
    public static function send($msg_type,$event_type,$to,$data){
        $arr = [
            'msg_type'=>$msg_type,
            'event_type'=>$event_type,
            'to'=>$to,
            'data'=>$data
        ];
        $client = stream_socket_client(\Yii::$app->params['ws_url'], $errno, $errmsg, 1);
        // 发送数据，注意5678端口是Text协议的端口，Text协议需要在数据末尾加上换行符
        $result = fwrite($client, Json::encode($arr)."\n");
        fclose($client);
        return $result;
    }
}